package com.init.system.converter;

import com.init.system.filter.TokenBucket;
import org.springframework.stereotype.Service;

import java.util.concurrent.TimeUnit;
@Service
public class ApiService {
    private final TokenBucket tokenBucket;

    public ApiService() {
        // 设置最大令牌数、每次填充的令牌数、填充的时间间隔（例如10个令牌每秒）
        this.tokenBucket = new TokenBucket(10, 1, TimeUnit.SECONDS.toMillis(1));
    }
    public void handleRequest() {
        if (tokenBucket.tryAcquire()) {
            // 允许请求处理
            System.out.println("请求被处理");
        } else {
            // 拒绝请求
            System.out.println("请求被拒绝，超过限流");
        }
    }
}
